package com.ds.lens.flink.monitor.metricsjob;

import org.apache.flink.api.java.functions.KeySelector;

public class MetricsTagsKeySelector implements KeySelector<Metrics, String> {
    @Override
    public String getKey(Metrics value) throws Exception {
        return value.getAppKey();
    }
}
